#pragma once

#include <SimpleAmqpClient/SimpleAmqpClient.h>
#include <string>
#include <memory>

class RabbitMQClient {
public:
    RabbitMQClient(const std::string& uri, const std::string& exchange, const std::string& queue, const std::string& routing_key);
    ~RabbitMQClient();

    bool publish(const std::string& message);
    std::string consume();

private:  
    AmqpClient::Channel::ptr_t m_channel;
    std::string m_exchange;
    std::string m_queue;
    std::string m_routingKey;
};
